Debizium Oracle
Общее описание
Блок Debizium Oracle подключается к Oracle и отслеживает изменения в реальном времени через логическую репликацию. Преобразует изменения (INSERT, UPDATE, DELETE) в поток событий для дальнейшей обработки.
Блок Debizium Oracle может использоваться в качестве:
- блока – получателя.
Настройка блока
В данном разделе описаны параметры блока Debizium Oracle, которые необходимо заполнить при его настройке.
Базовые параметры
| Название в UI | Название атрибута | Описание | Значение по умолчанию | Тип данных |
|---|---|---|---|---|
| Name | name | Обязательный параметр Уникальное имя экземпляра коннектора Debezium. Используется системой Bercut ESB для его идентификации и регистрации. Попытка зарегистрировать коннектор с уже существующим именем приведет к ошибке. | Строка | |
| Connection | connection | Позволяет выбрать предсозданное подключение к серверу или создать новое с помощью визарда Connection Manager. | Список | |
| Description | description | Краткое описание блока. | Строка | |
| Additional Properties | additionalProperties | Позволяет задать свойства для компонента Debezium, которые нельзя установить напрямую в конфигурации системы. | Строка | |
| Internal Key Converter | internalKeyConverter | Класс конвертера для сериализации и десериализации ключевых данных смещений (offsets). Определяет формат хранения ключей в системе. | org.apache.kafka.connect.json.JsonConverter | Строка |
| Internal Value Converter | internalValueConverter | Класс‑конвертер для сериализации и десериализации данных смещений (offsets). Определяет формат хранения служебной информации о позициях чтения в источнике данных. | org.apache.kafka.connect.json.JsonConverter | Строка |
| Offset Commit Policy | offsetCommitPolicyClass | Класс Java, определяющий условия коммита офсетов (на основе количества обработанных событий и времени с последнего коммита). Должен реализовывать интерфейс OffsetCommitPolicy. | Строка | |
| Offset Commit Timeout Ms | offsetCommitTimeout | Максимальное время (в мс) ожидания фиксации записей и смещений разделов в хранилище смещений перед отменой операции и повторной попыткой в будущем | 5000 | Целое число |
| Offset Flush Interval Ms | offsetCommitInterval | Интервал попытки фиксации смещений (офсетов) | 60000 | Целое число |
| Offset Storage | offsetStorage | Класс, отвечающий за хранение смещений (offsets) коннектора. | org.apache.kafka.connect.storage.FileOffsetBackingStore | Строка |
| Offset Storage File Name | offsetStorageFileName | Путь к файлу, в котором хранятся смещения (offsets), если используется файловое хранилище. | Строка | |
| Offset Storage Partitions | offsetStoragePartitions | Количество партиций для топика смещений, если используется KafkaOffsetBackingStore. | Целое число | |
| Offset Storage Replication Factor | offsetStorageReplicationFactor | Фактор репликации для топика смещений. | Целое число | |
| Offset Storage Topic | offsetStorageTopic | Имя топика, используемого для хранения смещений. | Строка | |
| Archive Destination Name | archiveDestinationName | Задает конкретное место назначения архивных журналов (archive log destination) в Oracle как источник для чтения данных. Если параметр задан — коннектор читает архивные журналы только из указанного источника. Если не задан — автоматически выбирается первое доступное локальное и валидное (LOCAL и VALID) место назначения. Используется для точного контроля источника данных в средах с несколькими местами хранения архивных журналов (например, при репликации или резервном копировании). | Строка | |
| Archive Log Hours | archiveLogHours | Количество часов (относительно SYSDATE), за которые Debezium Oracle Connector будет анализировать архивные журналы (archive logs) для захвата изменений. Значение 0 — анализируются все доступные архивные журналы без ограничения по времени. Положительное число (например, 24) анализируются журналы за последние N часов. Позволяет сузить область поиска и ускорить инициализацию. Параметр помогает контролировать объем обрабатываемых данных при старте коннектора или восстановлении после сбоя. | 0 | Целое число |
| Binary Handling Mode | binaryHandlingMode | Способ обработки бинарных данных (bytes — как массив байтов). | bytes | Строка |
| Column Exclude List | columnExcludeList | Список столбцов (по шаблону), которые следует исключить из отслеживания изменений. | Строка | |
| Column Include List | columnIncludeList | Список столбцов (по шаблону), которые должны отслеживаться на изменения. | Строка | |
| Column Propagate Source Type | columnPropagateSourceType | Указывает, нужно ли передавать исходный тип данных столбца в схеме сообщения. | Строка | |
| Converters | converters | Опциональный список пользовательских конвертеров для преобразования данных (вместо стандартных). | Строка | |
| Custom Metric Tags | customMetricTags | Пользовательские теги (ключ‑значение) для настройки имени MBean‑объекта (метрики). | Строка | |
| Database Connection Adapter | databaseConnectionAdapter | Определяет адаптер для захвата изменений данных из Oracle БД. Возможные значения:
| LogMiner | Строка |
| Database Dbname | databaseDbname | Имя базы данных Oracle, из которой фиксируются изменения. | Строка | |
| Database Hostname | databaseHostname | Хост (адрес) сервера Oracle. | Строка | |
| Database Out Server Name | databaseOutServerName | Имя сервера XStream Out, к которому должен подключиться Debezium Oracle Connector для чтения изменений данных. Параметр используется при настройке репликации через Oracle XStream — технологию потоковой передачи изменений из Oracle БД. Указанное имя должно точно соответствовать конфигурации сервера XStream Out в целевой БД. | Строка | |
| Database Password | databasePassword | Обязательный параметр Пароль пользователя для подключения к Oracle. | Строка | |
| Database Pdb Name | databasePdbName | Имя подключаемой базы данных при работе с мультитенантной архитектурой Oracle (CDB/PDB). Используется совместно с параметром database.dbname, в котором указывается имя контейнерной базы данных (CDB). Без корректного указания обоих параметров подключение к PDB в мультитенантной среде невозможно. | Строка | |
| Database Port | databasePort | Порт сервера Oracle. | 1528 | Целое число |
| Database Query Timeout Ms | databaseQueryTimeoutMs | Тайм‑аут (в мс) для SQL‑запросов к БД. Может задаваться в формате времени (например, 10m). | 10m | Строка |
| Database Url | databaseUrl | Полный JDBC‑URL для подключения к Oracle БД. Используется как альтернатива указанию отдельных параметров (hostname, port, database). Позволяет реализовать нестандартные сценарии подключения (например, кластерные конфигурации, TNS‑имена, специальные параметры соединения). Формат: jdbc:oracle:thin:@//<host>:<port>/<service_name> или иные допустимые варианты JDBC для Oracle. | Строка | |
| Database User | databaseUser | Имя пользователя для подключения к серверу Oracle. | Строка | |
| Datatype Propagate Source Type | datatypePropagateSourceType | Передача исходного типа и длины данных БД в схеме сообщения (для кастомных типов). | Строка | |
| Decimal Handling Mode | decimalHandlingMode | Способ обработки десятичных чисел. Возможные значения:
| precise | Строка |
| Errors Max Retries | errorsMaxRetries | Максимальное число попыток повторной обработки ошибки ( -1 — бесконечно). | -1 | Целое число |
| Event Processing Failure Handling Mode | eventProcessingFailureHandlingMode | Стратегия обработки ошибок при обработке событий коннектором. Возможные значения:
| fail | Строка |
| Heartbeat Action Query | heartbeatActionQuery | SQL‑запрос, выполняемый при отправке сигнала «сердцебиения» (heartbeat) для поддержания активности соединения с СУБД и подтверждения работоспособности коннектора. | Строка | |
| Heartbeat Interval Ms | heartbeatIntervalMs | Определяет интервал в миллисекундах, с которым коннектор периодически отправляет сигналы «сердцебиения» (heartbeat) в специальный топик. Эти сигналы подтверждают активность коннектора, помогают отслеживать его состояние, а также предотвращают разрыв соединения из‑за бездействия. Зачение 0 отключает отправку heartbeat‑сигналов | 0ms | Строка |
| Heartbeat Topics Prefix | heartbeatTopicsPrefix | Задает префикс для префикс для темплейтов, связанных с heartbeat-событиями. Позволяет изолировать служебные сообщения от основных данных. | __debezium-heartbeat | Строка |
| Include Schema Changes | includeSchemaChanges | Определяет, должен ли Debezium Oracle Connector публиковать изменения схемы базы данных (DDL) в топик с именем, совпадающим с ID сервера БД. При включении (true) каждое изменение схемы записывается с ключом (имя БД) и значением (логическое описание новой схемы и, опционально, DDL‑операции). Параметр не влияет на внутреннее ведение истории схемы коннектором. | True | Логическое значение |
| Include Schema Comments | includeSchemaComments | Определяет, должен ли Debezium Oracle Connector извлекать комментарии к таблицам и колонкам и добавлять их в объекты метаданных. Важно: включение (true) увеличивает потребление памяти, поскольку для каждой колонки создается дополнительный строковый объект. | False | Логическое значение |
| Incremental Snapshot Watermarking Strategy | incrementalSnapshotWatermarkingStrategy | Определяет стратегию установки водяных знаков (watermark) для отслеживания прогресса инкрементного снимка. Возможные значения:
| INSERT_INSERT | Строка |
| Interval Handling Mode | intervalHandlingMode | Задает способ представления интервальных типов данных в сообщениях. Возможные значения:
| numeric | Строка |
| Lob Enabled | lobEnabled | Определяет, активирован ли функционал работы с линиями бизнеса (LOB). При включении система учитывает разделение данных по LOB. | false | Логическое значение |
| Log Mining Archive Log Only Mode | logMiningArchiveLogOnlyMode | Включает режим, при котором механизм добычи логов работает только с архивными логами, игнорируя оперативные. Полезен для анализа исторических данных без влияния на текущую работу системы. | false | Логическое значение |
| Log Mining Archive Log Only Scn Poll Interval Ms | logMiningArchiveLogOnlyScnPollIntervalMs | Задает интервал (в миллисекундах) между опросами системного изменения номера (SCN) в режиме работы только с архивными логами. Больший интервал снижает нагрузку на систему, но может увеличить задержку обнаружения изменений. | 10s | Строка |
| Log Mining Batch Size Default | logMiningBatchSizeDefault | Устанавливает стандартный размер пакета записей, обрабатываемых механизмом добычи логов за одну итерацию. Оптимальное значение балансирует пропускную способность и нагрузку на память. | 20000 | Целое число |
| Log Mining Batch Size Max | logMiningBatchSizeMax | Задает максимально допустимый размер пакета записей для механизма добычи логов. Ограничивает пиковую нагрузку на память при обработке больших объемов данных. | 100000 | Целое число |
| Log Mining Batch Size Min | logMiningBatchSizeMin | Определяет минимально допустимый размер пакета записей. Предотвращает чрезмерное дробление данных, которое может снизить общую производительность системы. | 1000 | Целое число |
| Log Mining Buffer Drop On Stop | logMiningBufferDropOnStop | Управляет поведением буфера при остановке механизма добычи логов: если включено, буфер очищается; если отключено, данные сохраняются для возобновления работы. | false | Логическое значение |
| Log Mining Buffer Infinispan Cache Events | logMiningBufferInfinispanCacheEvents | Включает использование кэша Infinispan для хранения событий в буфере добычи логов. Ускоряет доступ к данным при высокой нагрузке. | Строка | |
| Log Mining Buffer Infinispan Cache Global | logMiningBufferInfinispanCacheGlobal | Активирует глобальный кэш Infinispan, доступный для всех компонентов системы. Обеспечивает централизованное хранение данных буфера. | Строка | |
| Log Mining Buffer Infinispan Cache Processed Transactions | logMiningBufferInfinispanCacheProcessedTransactions | Сохраняет в кэше Infinispan информацию о обработанных транзакциях. Позволяет отслеживать прогресс и восстанавливать состояние после сбоев. | Строка | |
| Log Mining Buffer Infinispan Cache Schema Changes | logMiningBufferInfinispanCacheSchemaChanges | Кэширует изменения схемы базы данных (DDL‑операции) в Infinispan. Упрощает синхронизацию структуры данных между компонентами. | Строка | |
| Log Mining Buffer Infinispan Cache Transactions | logMiningBufferInfinispanCacheTransactions | Использует кэш Infinispan для буферизации транзакций. Оптимизирует обработку больших транзакций и снижает задержки. | Строка | |
| Log Mining Buffer Transaction Events Threshold | logMiningBufferTransactionEventsThreshold | Задает пороговое количество событий транзакции, при достижении которого буфер активирует дополнительные механизмы обработки. Помогает управлять нагрузкой. | 0 | Целое число |
| Log Mining Buffer Type memory | logMiningBufferType | Определяет тип буфера для механизма добычи логов. Вариант memory использует оперативную память, обеспечивая максимальную скорость. | memory | Строка |
| Log Mining Flush Table Name | logMiningFlushTableName | Указывает имя таблицы, используемой для принудительной очистки буфера добычи логов. Позволяет вручную управлять сбросом данных в хранилище. | LOG_MINING_FLUSH | Строка |
| Log Mining Include Redo Sql | logMiningIncludeRedoSql | Активриует включение SQL‑запросов из redo‑логов в выходные данные. Полезно для отладки и аудита изменений в базе данных. | False | Логическое значение |
| Log Mining Query Filter Mode none | logMiningQueryFilterMode | Задает режим фильтрации запросов при добыче логов. Значение none отключает фильтрацию, возвращая все данные без ограничений. | none | Строка |
| Log Mining Restart Connection | logMiningRestartConnection | Управляет автоматическим переподключением к базе данных при сбоях соединения в процессе добычи логов. Повышает устойчивость системы. | False | Логическое значение |
| Log Mining Scn Gap Detection Gap Size Min | logMiningScnGapDetectionGapSizeMin | Устанавливает минимальный размер разрыва SCN (системного изменения номера), который считается значимым. Помогает выявлять пропуски в логах. | 1000000 | Целое число |
| Log Mining Scn Gap Detection Time Interval Max Ms 20s | logMiningScnGapDetectionTimeIntervalMaxMs | Задает максимальный временной интервал (в мс) без изменений SCN, после которого система фиксирует разрыв. Предотвращает зависания при отсутствии данных. | 20000 | Целое число |
| Log Mining Session Max Ms | logMiningSessionMaxMs | Ограничивает максимальную длительность сессии добычи логов (в мс). Значение 0 снимает ограничение, позволяя сессии работать бесконечно. | 0ms | Строка |
| Log Mining Sleep Time Default Ms | logMiningSleepTimeDefaultMs | Устанавливает стандартное время паузы (в мс) между операциями добычи логов. Балансирует нагрузку и отзывчивость системы. | 1s | Строка |
| Log Mining Sleep Time Increment Ms | logMiningSleepTimeIncrementMs | Определяет шаг увеличения времени паузы (в мс) при адаптивной настройке. Помогает плавно регулировать нагрузку. | 200ms | Строка |
| Log Mining Sleep Time Max Ms | logMiningSleepTimeMaxMs | Задает максимальное время паузы (в мс) между операциями. Предотвращает чрезмерно долгие задержки в обработке данных. | 3s | Строка |
| Log Mining Sleep Time Min Ms | logMiningSleepTimeMinMs | Устанавливает минимальное время паузы (в мс). Значение 0 позволяет выполнять операции без задержек при низкой нагрузке. | 0ms | Строка |
| Log Mining Strategy redo_log_catalog | logMiningStrategy | Определяет стратегию добычи логов. Вариант redo_log_catalog использует каталог redo‑логов, оптимизируя чтение изменений схемы. | redo_log_catalog | Строка |
| Log Mining Transaction Retention Ms 0ms | logMiningTransactionRetentionMs | Задает время хранения транзакций в буфере (в мс). Значение 0 отключает ограничение, сохраняя данные до ручной очистки. | 0 | Целое число |
| Log Mining Username Exclude List | logMiningUsernameExcludeList | Список пользователей базы данных, чьи действия исключаются из добычи логов. Используется для фильтрации служебных или тестовых операций. | Строка | |
| Log Mining Username Include List | logMiningUsernameIncludeList | Список пользователей, чьи действия отслеживаются механизмом добычи логов. Все остальные игнорируются. Позволяет сузить область мониторинга. | Строка | |
| Max Batch Size | maxBatchSize | Максимальное количество записей из источника, обрабатываемых в одном пакете за итерацию. Увеличение значения может повысить пропускную способность, но увеличит нагрузку на память и задержку обработки. Уменьшение значения снижает нагрузку, но может снизить общую производительность. | 2048 | Целое число |
| Max Queue Size | maxQueueSize | Максимальный размер очереди для событий изменений, прочитанных из журнала базы данных, но еще не записанных и не переданных дальше. Должен быть всегда больше максимального размера батча (maxBatchSize). Позволяет буферизовать данные при временных задержках в обработке или отправке. | 8192 | Целое число |
| Max Queue Size In Bytes | maxQueueSizeInBytes | Максимальный объем очереди (в байтах) для событий изменений, прочитанных из журнала базы данных, но еще не записанных и не переданных дальше. Значение 0 означает, что ограничение по объему отключено — очередь может расти без жестких лимитов по размеру (ограничения могут накладываться другими механизмами). Позволяет контролировать потребление памяти и предотвращать переполнение при пиковых нагрузках. | 0 | Целое число |
| Message Key Columns | messageKeyColumns | Список выражений (разделенных точкой с запятой), определяющих полные имена таблиц и колонок, которые будут использоваться в качестве ключа сообщения. Формат каждого выражения: DB_NAME.TABLE_NAME:COLUMN_NAME или SCHEMA_NAME.TABLE_NAME:COLUMN_NAME. | Строка | |
| Notification Enabled Channels | notificationEnabledChannels | Список имен каналов уведомлений, которые активированы. Возможные значения зависят от реализации системы. | Строка | |
| Notification Sink Topic Name | notificationSinkTopicName | Имя топика, в который отправляются уведомления. Обязательно, если в списке включенных каналов (notificationEnabledChannels) присутствует значение sink. | Строка | |
| Openlogreplicator Host | openlogreplicatorHost | Хостнейм сетевого сервиса OpenLogReplicator, используемого для чтения журналов изменений Oracle (redo logs). Указывается в виде доменного имени или IP‑адреса. | Строка | |
| Openlogreplicator Port | openlogreplicatorPort | Номер порта сетевого сервиса OpenLogReplicator, используемого для чтения журналов изменений Oracle (redo logs). | Целое число | |
| Openlogreplicator Source | openlogreplicatorSource | Логическое имя источника данных в конфигурации OpenLogReplicator, из которого будут передаваться изменения (change stream). Имя должно точно соответствовать настройке source в конфигурации сервиса OpenLogReplicator. | Строка | |
| Poll Interval Ms | pollIntervalMs | Время (в миллисекундах), которое коннектор ожидает появления новых событий изменений после того, как не получил ни одного события в предыдущем цикле опроса. Коннектор приостанавливается на указанный период перед следующим запросом к источнику данных. | 500ms | Строка |
| Post Processors | postProcessors | Опциональный список пост‑процессоров. Процессоры определяются через параметр .type , настраиваются дополнительными опциями. | Строка | |
| Provide Transaction Metadata | provideTransactionMetadata | Включает извлечение метаданных транзакции вместе с подсчетом событий. | False | Логическое значение |
| Query Fetch Size | queryFetchSize | Максимальное число записей, загружаемых в память при потоковой передаче данных. Значение 0 использует размер выборки JDBC по умолчанию. | 10000 | Целое число |
| Rac Nodes | racNodes | Список хостнеймов или IP‑адресов узлов Oracle Real Application Clusters (RAC), разделенных запятыми. Используется для корректного подключения к кластерной конфигурации Oracle. Формат: hostname1,hostname2,... или ip1,ip2,.... | Строка | |
| Retriable Restart Connector Wait Ms | retriableRestartConnectorWaitMs | Время ожидания (в миллисекундах) перед перезапуском коннектора после возникновения повторяемой ошибки (retriable exception). | 10s | Строка |
| Schema History Internal | schemaHistoryInternal | Имя класса SchemaHistory, используемого Debezium для сохранения и восстановления изменений схемы БД. | io.debezium.storage.kafka.history.KafkaSchemaHistory | Строка |
| Schema History Internal File Filename | schemaIncludeList | Список схем, для которых должны захватываться события изменений. Используется для фильтрации по схемам — реплицируются только указанные схемы. | Строка | |
| Schema History Internal Skip Unparseable Ddl | schemaHistoryInternalSkipUnparseableDdl | Управляет поведением коннектора Debezium при обнаружении в бинарном логе (binlog) DDL‑операции, которую коннектор не может распознать/распарсить. Если false, то при встрече с нераспознаваемой DDL‑операцией коннектор останавливает работу и переходит в состояние ошибки. Это гарантирует целостность метаданных, но требует ручного вмешательства для восстановления. | False | Логическое значение |
| Schema History Internal Store Only Captured Databases Ddl | schemaHistoryInternalStoreOnlyCapturedDatabasesDdl | Управляет тем, какие DDL‑операции Debezium будет сохранять в истории схемы базы данных. Если false, коннектор сохраняет все входящие DDL‑операции из бинарного лога (binlog), независимо от того, к какой базе данных или схеме они относятся. При true коннектор сохраняет только DDL‑операции, которые затрагивают таблицы из отслеживаемых (captured) баз данных/схем, настроенных в коннекторе. | False | Логическое значение |
| Schema History Internal Store Only Captured Tables Ddl | schemaHistoryInternalStoreOnlyCapturedTablesDdl | Определяет, какие DDL‑операции Debezium сохраняет в истории схемы БД. При false: сохраняются все входящие DDL‑операции из binlog. Если true: сохраняются только DDL‑операции, затрагивающие отслеживаемые таблицы. | False | Логическое значение |
| Schema Name Adjustment Mode | schemaNameAdjustmentMode | Определяет способ корректировки имен схем для совместимости с конвертером сообщений. Возможные значения:
| none | Строка |
| Signal Data Collection | signalDataCollection | Имя коллекции данных, используемой для отправки сигналов/команд в Debezium. Для многораздельных коннекторов можно указать несколько коллекций через запятую. При отсутствии значения сигнализация отключена. | Строка | |
| Signal Enabled Channels | signalEnabledChannels | Список имен каналов, через которые принимаются сигналы управления. Канал source включен по умолчанию. Возможные значения:
| source | Строка |
| Signal Poll Interval Ms | signalPollIntervalMs | Интервал (в миллисекундах) для проверки новых сигналов в зарегистрированных каналах. | 5s | Строка |
| Skipped Operations | skippedOperations | Список операций (через запятую), пропускаемых во время потоковой передачи. Возможные значения:
| t | Строка |
| Snapshot Database Errors Max Retries | snapshotDatabaseErrorsMaxRetries | Количество попыток повторить операцию при возникновении ошибок базы данных во время создания снапшота (полного считывания данных) перед тем, как признать операцию неудачной. Параметр позволяет повысить устойчивость коннектора к временным проблемам с БД. | 0 | Целое число |
| Snapshot Delay Ms | snapshotDelayMs | Задержка (в миллисекундах) перед началом снимка данных. Позволяет отложить старт репликации для подготовки окружения. | 0ms | Строка |
| Snapshot Fetch Size | snapshotFetchSize | Максимальное число записей, загружаемых в память при выполнении снимка данных (snapshot). | Целое число | |
| Snapshot Include Collection List | snapshotIncludeCollectionList | Список таблиц/коллекций, для которых должен быть выполнен снимок данных при создании или перезапуске коннектора. | Строка | |
| Snapshot Locking Mode | snapshotLockingMode | Задает способ удержания блокировок таблиц во время выполнения снимка схемы. Возможные значения:
| shared | Строка |
| Snapshot Locking Mode Custom Name | snapshotLockingModeCustomName | Имя пользовательской реализации (реализует интерфейс SnapshotterLocking), определяющей способ блокировки таблиц во время снимка схемы (используется при snapshotLockingMode=custom). | Строка | |
| Snapshot Lock Timeout Ms | snapshotLockTimeoutMs | Максимальное время (в миллисекундах) ожидания блокировок таблиц в начале снимка. Если блокировки не получены за это время, снимок прерывается. | 10s | Строка |
| Snapshot Max Threads | snapshotMaxThreads | Максимальное количество потоков, используемых для выполнения снимка данных. | 1 | Целое число |
| Snapshot Mode | snapshotMode | Определяет условия запуска снимка при старте коннектора. Возможные значения:
| initial | Строка |
| Snapshot Mode Configuration Based Snapshot Data | snapshotModeConfigurationBasedSnapshotData | Указывает, нужно ли снимать данные при режиме configuration_based. | False | Логическое значение |
| Snapshot Mode Configuration Based Snapshot On Data Error | snapshotModeConfigurationBasedSnapshotOnDataError | Указывает, нужно ли снимать данные в случае ошибки при режиме configuration_based. | False | Логическое значение |
| Snapshot Mode Configuration Based Snapshot On Schema Error | snapshotModeConfigurationBasedSnapshotOnSchemaError | Указывает, нужно ли снимать схему в случае ошибки при режиме configuration_based. | False | Логическое значение |
| Snapshot Mode Configuration Based Snapshot Schema | snapshotModeConfigurationBasedSnapshotSchema | Указывает, нужно ли снимать схему при режиме configuration_based. | False | Логическое значение |
| Snapshot Mode Configuration Based Start Stream | snapshotModeConfigurationBasedStartStream | Указывает, нужно ли запускать поток изменений после снимка при режиме configuration_based. | False | Логическое значение |
| Snapshot Mode Custom Name | snapshotModeCustomName | Имя пользовательской реализации (реализует интерфейс Snapshotter), определяющей логику снимка (используется при snapshotMode=custom). | Строка | |
| Snapshot Select Statement Overrides | snapshotSelectStatementOverrides | Список таблиц (через запятую) с переопределенными SELECT‑запросами для снимка. Позволяет задать кастомные запросы для отдельных таблиц. Формат: DB_NAME.TABLE_NAME или SCHEMA_NAME.TABLE_NAME. | Строка | |
| Snapshot Tables Order By Row Count | snapshotTablesOrderByRowCount | Определяет порядок обработки таблиц в начальном снимке по количеству строк. Возможные значения:
| disabled | Строка |
| Sourceinfo Struct Maker | sourceinfoStructMaker | Имя класса SourceInfoStructMaker, который возвращает схему и структуру SourceInfo для событий репликации. | io.debezium.connector.oracle.OracleSourceInfoStructMaker | Строка |
| Streaming Delay Ms | streamingDelayMs | Задержка (в миллисекундах) между завершением снимка данных и началом потоковой передачи изменений. Позволяет выполнить дополнительные подготовительные действия. | 0ms | Строка |
| Table Exclude List | tableExcludeList | Список регулярных выражений (через запятую), сопоставляемых с полными именами таблиц, которые следует исключить из мониторинга. Позволяет фильтровать таблицы по шаблонам. | Строка | |
| Table Include List | tableIncludeList | Список таблиц, для которых должны захватываться изменения данных. Используется для точной настройки репликации — обрабатываются только указанные таблицы. | Строка | |
| Time Precision Mode | timePrecisionMode | Определяет способ представления временных типов данных (TIME, DATE, TIMESTAMP). Возможные значения:
| adaptive | Строка |
| Tombstones On Delete | tombstonesOnDelete | Указывает, следует ли представлять операции удаления как два события: событие удаления и последующее «надгробие» (tombstone). Если true, система может полностью удалить все события с данным ключом после удаления записи в источнике. | False | Логическое значение |
| Topic Naming Strategy | topicNamingStrategy | Имя класса TopicNamingStrategy, определяющего правила формирования имен топиков для разных типов событий (изменения данных, схемы, транзакции, heartbeat и т. д.). | io.debezium.schema.SchemaTopicNamingStrategy | Строка |
| Topic Prefix | topicPrefix | Обязательный параметр Префикс топиков, идентифицирующий сервер/кластер БД. Должен быть уникальным для всех коннекторов. Используется как основа для имен топиков. Допустимы: буквы, цифры, дефисы, точки, подчеркивания. | Строка | |
| Transaction Metadata Factory | transactionMetadataFactory | Класс, отвечающий за создание контекста транзакции и структур/схем транзакций. Определяет, как будут представлены транзакции в событиях репликации. | io.debezium.pipeline.txmetadata.DefaultTransactionMetadataFactory | Строка |
| Unavailable Value Placeholder | unavailableValuePlaceholder | Константа, указывающая, что исходное значение является TOAST‑значением, не предоставленным БД. Если начинается с hex:, оставшаяся часть строки интерпретируется как шестнадцатеричное представление октетов. | __debezium_unavailable_value | Строка |
Расширенные параметры
| Название в UI | Название атрибута | Описание | Значение по умолчанию | Тип данных |
|---|---|---|---|---|
| Bridge Error Handler | bridgeErrorHandler | Определяет стратегию обработки ошибок на уровне интеграционного моста (bridge) в Bercut ESB. Отвечает за реакцию системы на сбои при передаче сообщений между компонентами. Может включать повторные попытки отправки, перенаправление в очередь ошибок, логирование и т. д. Функция доступна только для тех сторонних компонентов, которые позволяют системе получать уведомления о возникших исключениях. Некоторые компоненты обрабатывают ошибки внутри себя — в таких случаях использование bridgeErrorHandler невозможно. | False | Логическое значение |
| Exception Handler | exceptionHandler | Определяет стратегию обработки исключений на уровне компонента. По умолчанию используется стандартный обработчик org.apache.camel.spi.ExceptionHandler, который логирует ошибки на уровнях WARN или ERROR и игнорирует их. Позволяет настроить кастомную логику обработки (повторные попытки, перенаправление в очередь ошибок и т. д.). | Строка | |
| Exchange Pattern | exchangePattern | Задает шаблон взаимодействия между компонентами в интеграционном потоке. Определяет способ передачи сообщений и ожидания ответа. Возможные значения:
| Строка |